package cn.z2huo.demo.hello.kafka.api;

import cn.z2huo.demo.hello.kafka.model.KafkaOffset;

import java.util.List;

/**
 * <p>
 *
 * @author z2huo
 */
public interface KafkaOffsetDAO {

    List<KafkaOffset> list(String consumerName, String groupId, List<String> topics);

    void store(KafkaOffset kafkaOffset);

}
